package com.hisense.ovcloud.warehouse.amq;

import com.hisense.ovcloud.commons.configs.activemq.AMQConsumer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;

import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.TextMessage;

@Component
@Order(100)
@Slf4j
public class TestConsumer implements AMQConsumer {
    @Override
    public void consume(Message msg) throws JMSException {
        log.info("new TestConsumer msg: " + ((TextMessage)msg).getText());
    }
}
